package com.lkx.kafka.monitor.dto;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.Date;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class ClusterMetrics {
    // 集群基本信息
    private String clusterName;
    private int brokerCount;
    private int topicCount;
    private int partitionCount;
    private int replicaCount;

    // 流量指标
    private long messageTotal24h;
    private double produceRate; // 消息/秒
    private double consumeRate; // 消息/秒

    // 状态信息
    private String clusterStatus; // 健康/警告/异常
    private Date lastUpdateTime;
}